<!doctype html>
<html class="no-js" lang="">
    <head>
        <meta charset="utf-8">
        <meta http-equiv="x-ua-compatible" content="ie=edge">
        <title>Nestify</title>
        <meta name="description" content="">
        <meta name="viewport" content="width=device-width, initial-scale=1">

        <link rel="icon" type="image/x-icon" href="../images/favicon.ico">
	      <link rel="stylesheet" href="../styles/style.css">
    </head>
    <body>

        <div class="navbar navbar-default navbar-fixed-top visible-xs">
            <a href="../" class="navbar-brand">Nestify</a>
            <button type="button" class="btn btn-default btn-menu ion-ios-menu" id="btn-menu"></button>
        </div>

        <div class="xs-menu menu" id="mobile-menu">
                <div id="book-search-input" role="search"><input type="text" placeholder="请输入查询关键字"></div>            <compodoc-menu></compodoc-menu>
        </div>

        <div class="container-fluid main">
           <div class="row main">
               <div class="hidden-xs menu">
                   <compodoc-menu mode="normal"></compodoc-menu>
               </div>
               <!-- START CONTENT -->
               <div class="content class">
                   <div class="content-data">











<ol class="breadcrumb">
  <li>类列表</li>
  <li>StatusTask</li>
</ol>

<ul class="nav nav-tabs" role="tablist">
        <li class="active">
            <a href="#info" role="tab" id="info-tab" data-toggle="tab" data-link="info">Info</a>
        </li>
        <li >
            <a href="#source" role="tab" id="source-tab" data-toggle="tab" data-link="source">Source</a>
        </li>
</ul>

<div class="tab-content">
    <div class="tab-pane fade active in" id="c-info">
        <p class="comment">
            <h3>文件</h3>
        </p>
        <p class="comment">
            <code>server/src/common/tasks/status.task.ts</code>
        </p>


            <p class="comment">
                <h3>继承</h3>
            </p>
            <p class="comment">
                        <code><a href="../miscellaneous/variables.html#es" target="_self" >NestSchedule</a></code>
            </p>



            <section>
    <h3 id="index">索引</h3>
    <table class="table table-sm table-bordered index-table">
        <tbody>
                <tr>
                    <td class="col-md-4">
                        <h6><b>属性列表</b></h6>
                    </td>
                </tr>
                <tr>
                    <td class="col-md-4">
                        <ul class="index-list">
                            <li>
                                <a href="#server">server</a>
                            </li>
                        </ul>
                    </td>
                </tr>

                <tr>
                    <td class="col-md-4">
                        <h6><b>方法</b></h6>
                    </td>
                </tr>
                <tr>
                    <td class="col-md-4">
                        <ul class="index-list">
                            <li>
                                    <span class="modifier">Async</span>
                                <a href="#intervalJob">intervalJob</a>
                            </li>
                            <li>
                                    <span class="modifier">Async</span>
                                <a href="#pushStatus">pushStatus</a>
                            </li>
                            <li>
                                    <span class="modifier">Async</span>
                                <a href="#watchFiles">watchFiles</a>
                            </li>
                        </ul>
                    </td>
                </tr>





        </tbody>
    </table>
</section>

            <section>
    <h3 id="constructor">构造方法</h3>
        <table class="table table-sm table-bordered">
            <tbody>
                <tr>
                    <td class="col-md-4">
<code>constructor()</code>
                    </td>
                </tr>
                        <tr>
                            <td class="col-md-4">
                                <div class="io-line">被定义在 <a href="" data-line="14" class="link-to-prism">server/src/common/tasks/status.task.ts:14</a></div>
                            </td>
                        </tr>

            </tbody>
        </table>
</section>

            <section>
    
        <h3 id="inputs">
            属性列表
        </h3>
        <table class="table table-sm table-bordered">
            <tbody>
                <tr>
                    <td class="col-md-4">
                        <a name="server"></a>
                        <span class="name">
                            <b>
                            server</b>
                            <a href="#server"><span class="icon ion-ios-link"></span></a>
                        </span>
                    </td>
                </tr>
                    <tr>
                        <td class="col-md-4">
                            <i>类型 : </i>        <code><a href="https://www.typescriptlang.org/docs/handbook/basic-types.html" target="_blank" >any</a></code>

                        </td>
                    </tr>
                    <tr>
                        <td class="col-md-4">
                            <b>装饰器列表 : </b>
                            <br />
                            <code>
                                @WebSocketServer()<br />
                            </code>
                        </td>
                    </tr>
                        <tr>
                            <td class="col-md-4">
                                    <div class="io-line">被定义在 <a href="" data-line="14" class="link-to-prism">server/src/common/tasks/status.task.ts:14</a></div>
                            </td>
                        </tr>


            </tbody>
        </table>
</section>

            <section>
    
    <h3 id="methods">
        方法
    </h3>
    <table class="table table-sm table-bordered">
        <tbody>
            <tr>
                <td class="col-md-4">
                    <a name="intervalJob"></a>
                    <span class="name">
                        <b>
                            <span class="modifier">Async</span>
                            intervalJob
                        </b>
                        <a href="#intervalJob"><span class="icon ion-ios-link"></span></a>
                    </span>
                </td>
            </tr>
            <tr>
                <td class="col-md-4">
                    <span class="modifier-icon icon ion-ios-reset"></span>
                    <code>intervalJob()</code>
                </td>
            </tr>

            <tr>
                <td class="col-md-4">
                    <b>装饰器列表 : </b>
                    <br />
                    <code>@Interval(3000)<br /></code>
                </td>
            </tr>

            <tr>
                <td class="col-md-4">
                    <div class="io-line">被定义在 <a href="" data-line="129"
                            class="link-to-prism">server/src/common/tasks/status.task.ts:129</a></div>
                </td>
            </tr>


            <tr>
                <td class="col-md-4">

                    <div class="io-description">
                        <b>返回 : </b>    <code>{}</code>

                    </div>
                </td>
            </tr>
        </tbody>
    </table>
    <table class="table table-sm table-bordered">
        <tbody>
            <tr>
                <td class="col-md-4">
                    <a name="pushStatus"></a>
                    <span class="name">
                        <b>
                            <span class="modifier">Async</span>
                            pushStatus
                        </b>
                        <a href="#pushStatus"><span class="icon ion-ios-link"></span></a>
                    </span>
                </td>
            </tr>
            <tr>
                <td class="col-md-4">
                    <span class="modifier-icon icon ion-ios-reset"></span>
                    <code>pushStatus()</code>
                </td>
            </tr>

            <tr>
                <td class="col-md-4">
                    <b>装饰器列表 : </b>
                    <br />
                    <code>@Interval(3000)<br /></code>
                </td>
            </tr>

            <tr>
                <td class="col-md-4">
                    <div class="io-line">被定义在 <a href="" data-line="119"
                            class="link-to-prism">server/src/common/tasks/status.task.ts:119</a></div>
                </td>
            </tr>


            <tr>
                <td class="col-md-4">

                    <div class="io-description">
                        <b>返回 : </b>    <code>{}</code>

                    </div>
                </td>
            </tr>
        </tbody>
    </table>
    <table class="table table-sm table-bordered">
        <tbody>
            <tr>
                <td class="col-md-4">
                    <a name="watchFiles"></a>
                    <span class="name">
                        <b>
                            <span class="modifier">Async</span>
                            watchFiles
                        </b>
                        <a href="#watchFiles"><span class="icon ion-ios-link"></span></a>
                    </span>
                </td>
            </tr>
            <tr>
                <td class="col-md-4">
                    <span class="modifier-icon icon ion-ios-reset"></span>
                    <code>watchFiles()</code>
                </td>
            </tr>


            <tr>
                <td class="col-md-4">
                    <div class="io-line">被定义在 <a href="" data-line="45"
                            class="link-to-prism">server/src/common/tasks/status.task.ts:45</a></div>
                </td>
            </tr>


            <tr>
                <td class="col-md-4">

                    <div class="io-description">
                        <b>返回 : </b>        <code><a href="https://www.typescriptlang.org/docs/handbook/basic-types.html" target="_blank" >any</a></code>

                    </div>
                </td>
            </tr>
        </tbody>
    </table>
</section>





    </div>


    <div class="tab-pane fade  tab-source-code" id="c-source">
        <pre class="line-numbers compodoc-sourcecode"><code class="language-typescript">import { stat } from &#x27;fs&#x27;;
import { resolve, basename, dirname, extname } from &#x27;path&#x27;;
import * as pidusage from &#x27;pidusage&#x27;;
import * as chokidar from &#x27;chokidar&#x27;;
import { SubscribeMessage, WebSocketGateway, WebSocketServer } from &#x27;@nestjs/websockets&#x27;;
import { Cron, Interval, Timeout, NestSchedule } from &#x27;nest-schedule&#x27;;
import { influx } from &#x27;../lib/influx&#x27;;
import { Logger } from &#x27;../lib/logger&#x27;;
import { es } from &#x27;../lib/elastic-search&#x27;;
import { config } from &#x27;../../config&#x27;;

@WebSocketGateway(config.websocket.port, { namespace: &#x27;status&#x27; })
export class StatusTask extends NestSchedule {
    @WebSocketServer() server: any;

    constructor() {
        super();

        this.watchFiles();
    }

    // # ┌────────────── second (optional)
    // # │ ┌──────────── minute
    // # │ │ ┌────────── hour
    // # │ │ │ ┌──────── day of month
    // # │ │ │ │ ┌────── month
    // # │ │ │ │ │ ┌──── day of week
    // # │ │ │ │ │ │
    // # │ │ │ │ │ │
    // # * * * * * *

    // @Cron(&#x27;2 * * * * *&#x27;)
    // async cronJob() {
    //     Logger.log(&#x27;定时任务&#x27;);

    //     const status &#x3D; await pidusage(process.pid);
    //     Logger.log(status);
    // }

    // @Timeout(5000)
    // onceJob() {
    //     Logger.log(&#x27;延时任务&#x27;);
    // }

    async watchFiles() {
        const uploadDirPath &#x3D; resolve(&#x27;./static&#x27;);
        Logger.log(&#x60;watching ${uploadDirPath}&#x60;);

        chokidar.watch(uploadDirPath, { ignored: /(^|[\/\\])\../ }).on(&#x27;all&#x27;, (event, path) &#x3D;&gt; {
            // if (!!this.server) {
            //     this.server.emit(&#x27;fileChange&#x27;, { event, path, date });
            // }
            stat(path, (err, stats) &#x3D;&gt; {
                Logger.log(event, path, stats);

                const info &#x3D; { index: &#x27;uploads&#x27;, type: &#x27;uploads&#x27; };

                switch (event) {
                    case &#x27;add&#x27;:
                        es.index({
                            ...info,
                            id: path,
                            body: {
                                baseName: basename(path),
                                dirName: dirname(path),
                                extName: extname(path),
                                path,
                                type: &#x27;file&#x27;,
                                stat: stats
                            }
                        });
                        break;
                    case &#x27;addDir&#x27;:
                        es.index({
                            ...info,
                            id: path,
                            body: {
                                baseName: basename(path),
                                dirName: dirname(path),
                                extName: extname(path),
                                path,
                                type: &#x27;dir&#x27;,
                                stat: stats
                            }
                        });
                        break;
                    case &#x27;change&#x27;:
                        es.update({
                            ...info,
                            id: path,
                            body: {
                                baseName: basename(path),
                                dirName: dirname(path),
                                extName: extname(path),
                                path,
                                type: &#x27;dir&#x27;,
                                stat: stats
                            }
                        });
                        break;
                    case &#x27;unlink&#x27;:
                        es.delete({
                            ...info,
                            id: path
                        });
                        break;
                    case &#x27;unlinkDir&#x27;:
                        es.delete({
                            ...info,
                            id: path
                        });
                        break;
                }
            });
        });
    }

    @Interval(3000)
    async pushStatus() {
        if (!this.server) return false;

        const status &#x3D; await influx.query(
            &#x60;select * from system_status order by time desc limit 30&#x60;
        );
        this.server.emit(&#x27;status&#x27;, status);
    }

    @Interval(3000)
    async intervalJob() {
        const status &#x3D; await pidusage(process.pid);

        await influx.writePoints([
            {
                measurement: &#x27;system_status&#x27;,
                tags: { status: &#x27;status&#x27; },
                fields: status,
                timestamp: new Date()
            }
        ]);

        return false;
    }
}
</code></pre>
    </div>
</div>







                   </div><div class="search-results">
    <div class="has-results">
        <h1 class="search-results-title"><span class='search-results-count'></span> result-matching "<span class='search-query'></span>"</h1>
        <ul class="search-results-list"></ul>
    </div>
    <div class="no-results">
        <h1 class="search-results-title">无匹配的结果 "<span class='search-query'></span>"</h1>
    </div>
</div>
</div>
               <!-- END CONTENT -->
           </div>
       </div>

       <script>
            var COMPODOC_CURRENT_PAGE_DEPTH = 1;
            var COMPODOC_CURRENT_PAGE_CONTEXT = 'class';
            var COMPODOC_CURRENT_PAGE_URL = 'StatusTask.html';
       </script>

       <script src="../js/libs/custom-elements.min.js"></script>
       <script src="../js/libs/lit-html.js"></script>
       <!-- Required to polyfill modern browsers as code is ES5 for IE... -->
       <script src="../js/libs/custom-elements-es5-adapter.js" charset="utf-8" defer></script>
       <script src="../js/menu-wc.js" defer></script>

       <script src="../js/libs/bootstrap-native.js"></script>

       <script src="../js/libs/es6-shim.min.js"></script>
       <script src="../js/libs/EventDispatcher.js"></script>
       <script src="../js/libs/promise.min.js"></script>
       <script src="../js/libs/zepto.min.js"></script>

       <script src="../js/compodoc.js"></script>

       <script src="../js/tabs.js"></script>
       <script src="../js/menu.js"></script>
       <script src="../js/libs/clipboard.min.js"></script>
       <script src="../js/libs/prism.js"></script>
       <script src="../js/sourceCode.js"></script>
          <script src="../js/search/search.js"></script>
          <script src="../js/search/lunr.min.js"></script>
          <script src="../js/search/search-lunr.js"></script>
          <script src="../js/search/search_index.js"></script>
       <script src="../js/lazy-load-graphs.js"></script>


    </body>
</html>
